package com.smile.window;

public class CountWindow {
    //滚动窗口
//    DataStream<SensorReading> minTempPerWindowStream = dataStream
//            .keyBy(SensorReading::getId)
//            .countWindow( 5 )
//            .minBy("temperature");
   //滑动窗口
//    DataStream<SensorReading> minTempPerWindowStream = dataStream
//            .keyBy(SensorReading::getId)
//            .countWindow( 10, 2 )
//            .minBy("temperature");
}
